069e0289d45d9ab46561ff80142dc65426050c2d,twill-yarn/src/test/java/org/apache/twill/yarn/PlacementPolicyTestRun.java,PlacementPolicyTestRun,testChangeInstance,#,254
Before Change
Assert.assertTrue(waitForSize(serviceDiscovered, 4, 60));
// Increasing the instance count for runnable Alice by 2.
controller.changeInstances("Alice", 4);
serviceDiscovered = controller.discoverService("DistributedTest");
Assert.assertTrue(waitForSize(serviceDiscovered, 6, 60));
// Decreasing instance count for runnable Alice by 3.
controller.changeInstances("Alice", 1);
serviceDiscovered = controller.discoverService("DistributedTest");
Assert.assertTrue(waitForSize(serviceDiscovered, 3, 60));
// Increasing instance count for runnable Bob by 2.
controller.changeInstances("Bob", 3);
serviceDiscovered = controller.discoverService("DistributedTest");
Assert.assertTrue(waitForSize(serviceDiscovered, 5, 60));
After Change
Assert.assertTrue(waitForSize(serviceDiscovered, 4, 60));
// Increasing the instance count for runnable Alice by 2.
controller.changeInstances("Alice", 4).get(60, TimeUnit.SECONDS);
serviceDiscovered = controller.discoverService("DistributedTest");
Assert.assertTrue(waitForSize(serviceDiscovered, 6, 60));
// Decreasing instance count for runnable Alice by 3.
controller.changeInstances("Alice", 1).get(60, TimeUnit.SECONDS);
serviceDiscovered = controller.discoverService("DistributedTest");
Assert.assertTrue(waitForSize(serviceDiscovered, 3, 60));
// Increasing instance count for runnable Bob by 2.
controller.changeInstances("Bob", 3).get(60, TimeUnit.SECONDS);
serviceDiscovered = controller.discoverService("DistributedTest");
Assert.assertTrue(waitForSize(serviceDiscovered, 5, 60));